package cc.example;

import reactor.core.publisher.Flux;

public class 自定义元素处理handle {
    public static void main(String[] args) {
        Flux<Integer> flux = Flux.range(1, 10);
        Flux<Object> handle = flux.handle((integer, synchronousSink) -> {
            System.out.println("拿到的值 " + integer);
            String user = "张三" + integer;
            synchronousSink.next(user); // 可以向下游发送数据的水槽
        });


        handle.log().subscribe();

    }
}
